// 信息提示
// import { Message } from 'element-ui'
// 引入用户id
// import { getTenantId, getAccessToken } from '@/utils/auth'
// TOPIC_WARNING_WS = "/topic/warning";
// TOPIC_STATE_WS = "/topic/state";
// pubTOPIC_PREDICT = "/topic/predict";
// websocket地址
var url = 'ws://ws-service'
// websocket实例
var ws
// 重连定时器实例
var tt
// websocket重连开关
var websocketswitch = false
 
// websocket对象
var websocket = {
  // websocket建立连接
  Init (id) {
    // 判断浏览器是否支持websocket
    if (!'WebSocket' in window) {
      this.$modal.msgError('您的浏览器不支持WebSocket')
	  // alert("您的浏览器不支持socket");
      return
    }
    // console.log('getTenantId()', getTenantId())
    // 获取用户id
    // let userId = getTenantId()
    // 创建websocket实例
    ws = new WebSocket(url+id)
    // 监听websocket连接
    ws.onopen = function () {
      // Message({
      //   type: 'success',
      //   message: 'websocket连接成功'
      // })
	  this.socket.send(JSON.stringify({"app": "start"}));
	  console.log("socket连接成功");
    }
    // 监听websocket连接错误信息
    ws.onerror = function (e) {
      console.log('重连开关', websocketswitch)
      console.log('数据传输发生错误', e)
      // Message({
      //   message: 'websocket传输发生错误',
      //   type: 'error'
      // })
      // 打开重连
      reconnect()
    }
    // 监听websocket接受消息
    ws.onmessage = function (e) {
      console.log('接收后端消息:' + e.data)
      //心跳消息不做处理
      if (e.data === 'ok') {
        // return 
		alert('hhhh')
      }
      // Message({
      //   message: e.data,
      //   type: 'success'
      // })
    }
  },
  // websocket连接关闭方法
  Close () {
    //关闭断开重连机制
    websocketswitch = true
    ws.close()
  },
  // websocket发送信息方法
  Send (data) {
    // 处理发送数据JSON字符串
    let msg = JSON.stringify(data)
    // 发送消息给后端
    ws.send(msg)
  },
  // 暴露websocket实例
  getwebsocket () {
    return ws
  },
}
 
// 监听窗口关闭事件，当窗口关闭时-每一个页面关闭都会触发-扩张需求业务
// window.onbeforeunload = function () {
//   console.log('测试方法执行了')
// }
 
// // 浏览器刷新重新连接
// // 刷新页面后需要重连-并且是在登录之后
// if (window.performance.navigation.type == 1 && getAccessToken()) {
//   console.log('浏览器刷新了')
//   //刷新后重连
//   websocket.Init()
// }
// // 重连方法
// function reconnect () {
//   console.log('重连开关', websocketswitch)
//   // 判断是否主动关闭连接
//   if (websocketswitch) {
//     return
//   }
//   // 重连定时器-每次websocket错误方法onerror触发他都会触发
//   tt && clearTimeout(tt)
//   tt = setTimeout(function () {
//     console.log('执行断线重连...')
//     websocket.Init()
//     websocketswitch = false
//   }, 4000)
// } 
// 暴露对象
export default websocket
